package cn.tx.config;

/**
 * @author Mxb
 * @version 1.0
 * @date 2020/10/10 20:48
 */
//@Component
//public class ReturnsImpl implements RabbitTemplate.ReturnCallback {
//    @Autowired
//    private RabbitTemplate rabbitTemplate;
//
//    @Autowired
//    private ReturnsImpl returnsImpl;
//
//    @PostConstruct
//    private void initRabbitMQ(){
//        rabbitTemplate.setReturnCallback(returnsImpl);
//    }
//    /**
//     * 当消息到达队列失败时，回调的方法
//     * // 消息被退回了，我们可以把消息记录下来，分析错误的原因，以后重新发送，这
//     样的话，消息就不会在丢失了
//     * @param message 消息内容
//     * @param replyCode 回退的响应码
//     * @param replyText 响应文本
//     * @param exchange 该消息来自那个交互机
//     * @param routingKey 该消息路由key 为
//     */
//    @Override
//    public void returnedMessage(Message message, int replyCode, String
//            replyText, String exchange, String routingKey) {
//        System.out.println("===消息未正常到达队列===");
//        System.out.println("消息内容: "+message);
//        System.out.println("回退的响应码replyCode: "+replyCode);
//        System.out.println("响应文本replyText: "+replyText);
//        System.out.println("交互机exchange: "+exchange);
//        System.out.println("消息路由keyroutingKey: "+routingKey);
//    }
//}
